package org.apache.flink.runtime.rpc;

import java.util.concurrent.CompletableFuture;

/**
 * Interface for self gateways.
 * // TODO_MA 注释：RpcServer 是 Actor 与 RpcEndpoint 两层之间的胶合层
 */
public interface RpcServer extends StartStoppable, MainThreadExecutable, RpcGateway {

	/**
	 * Return a future which is completed when the rpc endpoint has been terminated.
	 *
	 * @return Future indicating when the rpc endpoint has been terminated
	 */
	CompletableFuture<Void> getTerminationFuture();
}
